#include "../mqserver/mq_channal.hpp"

int main()
{
    castlemq::ChannelManager::ptr cmp= std::make_shared<castlemq::ChannelManager>();
    cmp->openChannel("c1",muduo::net::TcpConnectionPtr(),castlemq::ProtobufCodecPtr(),castlemq::ConsumerManager::ptr(),
        std::make_shared<castlemq::VirtualHost>("host1","./data/host1/message","./data/host1/host1.db"),threadpool::ptr());
    return 0;
}